package com.microservice.stream;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 *  input 是相对自己来说，作为一个接受者通道
 *
 * @author:wesley
 */
public interface MySink {

    String input = "myInput";

    String input2 = "myInput2";

    @Input(MySink.input)
    SubscribableChannel input();

    @Input(MySink.input2)
    SubscribableChannel input2();

}
